package zm.irc.mqtt;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;

public class MyMqttCallback implements MqttCallback{
    @Override

    public void connectionLost(Throwable throwable) {

        System.out.println("connectionLost");

    }

    @Override

    public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {

        System.out.println("Topic: " + s + " Message: " + mqttMessage.toString());

    }

    @Override

    public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {

    }
}
